
import threading
import time
import queue
 
# def blocking_function(condition_func):
#     while not condition_func():
#         time.sleep(0.5)  # 每0.5秒检查一次条件
 
# # 使用方法
# condition = lambda: False  # 假设这是一个长时间执行的条件检查函数
# thread = threading.Thread(target=blocking_function, args=(condition,))
# thread.start()

q = queue.Queue(3)
q.put(1)
q.get()
# q.task_done()
q.join()